

package com.hazelcast.jet.impl.pipeline;

import com.hazelcast.jet.impl.pipeline.transform.SinkTransform;
import com.hazelcast.jet.pipeline.SinkStage;

import javax.annotation.Nonnull;

class SinkStageImpl extends AbstractStage implements SinkStage {

    SinkStageImpl(SinkTransform transform, PipelineImpl pipeline) {
        super(transform, pipeline);
    }

    @Nonnull
    @Override
    public SinkStage setLocalParallelism(int localParallelism) {
        super.setLocalParallelism(localParallelism);
        return this;
    }

    @Nonnull
    @Override
    public SinkStage setName(@Nonnull String name) {
        super.setName(name);
        return this;
    }
}
